# -*- coding:utf-8 -*-

from logger_config import logger_factory
from Slave.kafka.slave_consume import slave_main_consume

logger = logger_factory()


def queen_loop():
    """
    Queen节点循环访问mission_dict中的内容，读取任务信息并分配
    :return:
    """
    slave_main_consume()


def main():
    queen_loop()
